#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QObject>
#include <QThread>
#include <QDebug>
#include "mytest.h"

//mythread1用于操作sqlite数据库
//mythread2用于操作mysql数据库


class mythread1 : public QThread
{
    Q_OBJECT
public:
    explicit mythread1(QObject *parent = nullptr);

    void run() override;
    void addToSqlite(QString& str);  //像sqlite数据库中添加
    void opendatabase();   //打开数据库

public slots:
    void recvStr(QString str);//
    void select();
    void recvSelect();


signals:
    void sendVector(QVector<QString>);
private:
    QString str;
    QSqlDatabase database;
    QVector<QString> vv;
    bool flag1 = false; //用来标识sqlite数据是否打开
    bool flag2 = false; //用来标识插入操作
    bool flag3 = false; //用来标识查询操作
};


class mythread2 : public QThread
{
    Q_OBJECT
public:
    explicit mythread2(QObject *parent = nullptr);

    void run() override;

    void OpenMysql();

    void addMysql();

    void addMysqlSelect();

    void select();
public slots:

    void recvAdd(int id);

    void recvSelect(int id);

    void RecvAddSelect();
signals:
    void SendVector(QVector<QString>);

private:
     QSqlDatabase database1;

     bool flag1 = true;    //用来标识mysql数据库是否打开
     bool flag2 = false;   //用来标识日志的新增操作
     bool flag3 = false;   //用来标识日志的查询操作

     bool flag4 = false; //用来标识查询数据库日志信息
     int userid;

     QVector<QString> vv;
};

#endif // MYTHREAD_H
